package server

////封包拆包类实例，暂时不需要成员
//type DataPack struct{}
//
////封包拆包实例初始化方法
//func NewDataPack() *DataPack {
//	return &DataPack{}
//}
//
////获取包头长度方法
//func (dp *DataPack) GetHeadLen() uint32 {
//	//DataLen uint32(4字节)
//	return 4
//}
//
////封包方法(压缩数据)
//func (dp *DataPack) Pack(msg *RequestMessage) ([]byte, error) {
//	//创建一个存放bytes字节的缓冲
//	dataBuff := bytes.NewBuffer([]byte{})
//	if err := binary.Write(dataBuff, binary.LittleEndian, int8(0)); err != nil {
//		return nil, err
//	}
//	if err := binary.Write(dataBuff, binary.LittleEndian, msg.Seq); err != nil {
//		return nil, err
//	}
//	if err := binary.Write(dataBuff, binary.LittleEndian, msg.Seq); err != nil {
//		return nil, err
//	}
//	binaryutil.WriteUTF(dataBuff, binary.LittleEndian, msg.Route)
//	binaryutil.WriteUTF(dataBuff, binary.LittleEndian, string(msg.Rows))
//	return dataBuff.Bytes(), nil
//}
//
////拆包方法(解压数据)
//func (dp *DataPack) Unpack(reader io.Reader, maxPacketSize int) (*RequestMessage, error) {
//	//msg := &RequestMessage{}
//	//if err := binary.Read(reader, binary.LittleEndian, &msg.Seq); err != nil {
//	//	return nil, err
//	//}
//	//if err := binary.Read(reader, binary.LittleEndian, &msg.Byte); err != nil {
//	//	return nil, err
//	//}
//	//msg.Token = binaryutil.ReadUTF(reader, binary.LittleEndian)
//	//msg.Route = binaryutil.ReadUTF(reader, binary.LittleEndian)
//	//msg.Rows = []byte(binaryutil.ReadUTF(reader, binary.LittleEndian))
//	//
//	//logx.Debug(fmt.Sprintf("<<< seq=%v, msg=%v, data=%v\n", msg.Seq, msg.Route, string(msg.Rows)))
//	//
//	////判断dataLen的长度是否超出我们允许的最大包长度
//	//if maxPacketSize > 0 && len(msg.Rows) > maxPacketSize {
//	//	return nil, errors.New("too large msg data received")
//	//}
//
//	//这里只需要把head的数据拆包出来就可以了，然后再通过head的长度，再从conn读取一次数据
//	return
//}
